package com.ittx.dzt.meituan.consumer;

import com.ittx.dzt.meituan.constant.MeituanApiConstant;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.stereotype.Component;

/**
 * @Author: lfs
 * @Date: 2023/6/27 17:42
 */
@Slf4j
@Component
@RocketMQMessageListener(consumerGroup = MeituanApiConstant.Rocket.MEITUAN_PRODUCT_LIST_BY_TIME_BATCH_SPLIT_GROUP,
        topic = MeituanApiConstant.Rocket.MEITUAN_PRODUCT_LIST_BY_TIME_BATCH_SPLIT_TOPIC)
public class MeituanProductByTImeBatchSplitConsumer extends AbstractBatchSplitConsumer {

    @Override
    public String getLogsStr() {
        return "商品下载";
    }
}
